package com.github.yoojia.mqtt.boot;

import com.github.yoojia.mqtt.MQTTSocket;
import com.github.yoojia.mqtt.Message;

/**
 * 响应式消息执行器
 * @author Yoojia Chen (yoojiachen@gmail.com)
 * @since 1.0.0
 */
public interface ReqRepActuator extends Actuator {

    /**
     * 处理"请求-响应"的消息。
     * @param socket MQTTSocket
     * @param request 请求消息
     * @return Message 响应消息。
     */
    Message handleRequest(MQTTSocket socket, Message request);


}
